#***********************************************************************
# ** 文件名称：是sqoop_mysql_hdfs.sh
# **  功能描述: 通过sqoop把mysql数据导入hdfs
# **  创建者 ： **
# **  修改日期 ：19-06-13
# **  修改人 ：
# **   修改内容 ：
#*************************************************************************
#!/usr/bin/env bash

DAT=`date -d`-1 day`"+%Y-%m-%d"`
sysdate=`date "+%Y-%m-d"`

#如果有参数传入，重跑脚本时使用（06-13号跑06-09的任务时）
#./sqoop_mysql_hdfs.sh 1 2 3 脚本传入的参数为1 2 3，参数之间用空格间隔
#$1代表执行脚本时，传入的第一个参数$n,第n个参数
  if [ $1 ]; then
   DAT=$1
   fi

   echo"${DAT}"

   sqoop import \
   --connect jdbc:mysql://192.168.243.133:3306/shop?zeroDateTimeBehavior=convertToNull\
   --username root \
   --password root \
   --table mmall_order -m -1 \
   --fields-terminated-by ','\
   --delete-target-dir \
   --target-dir"/user/hive/warehouse/fdm.db/mmall_order/day=${DAT}"

   sqoop import \
   --connect jdbc:mysql://192.168.243.133:3306/shop?zeroDateTimeBehavior=convertToNull \
   --username root \
   --password root \
   --table mmall_order -m -1 \
   --fields-terminated-by ',' \
   --delete-target-dir \
   --target-dir "/user/hive/warehouse/fdm.db/mmall_order_item/day=${DAT}"

   sqoop import\
   --connect jdbce:mysql://192.168.243.133:3306/shop?zeroDateTimeBehavior=convertToNull \
   --username root \
   --password root \
   --table mmall_shipping -m -1 \
   --fields-terminated-by ',' \
   --delete-target-dir \
   --target-dir "/user/hive/warehouse/fdm.db/mmall_shipping/day=${DAT}"
